package org.apache.maven.artifact.manager;

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

import java.util.List;

import org.apache.maven.artifact.Artifact;
import org.apache.maven.artifact.repository.ArtifactRepository;
import org.apache.maven.artifact.repository.ArtifactRepositoryFactory;
import org.apache.maven.execution.MavenExecutionRequest;
import org.apache.maven.execution.MavenSession;
import org.apache.maven.plugin.LegacySupport;
import org.apache.maven.repository.MirrorSelector;
import org.apache.maven.settings.Mirror;
import org.apache.maven.settings.Proxy;
import org.apache.maven.settings.Server;
import org.apache.maven.settings.crypto.DefaultSettingsDecryptionRequest;
import org.apache.maven.settings.crypto.SettingsDecrypter;
import org.apache.maven.settings.crypto.SettingsDecryptionResult;
import org.apache.maven.wagon.ResourceDoesNotExistException;
import org.apache.maven.wagon.TransferFailedException;
import org.apache.maven.wagon.authentication.AuthenticationInfo;
import org.apache.maven.wagon.proxy.ProxyInfo;
import org.codehaus.plexus.component.annotations.Component;
import org.codehaus.plexus.component.annotations.Requirement;
import org.codehaus.plexus.logging.Logger;

@Component(role = WagonManager.class)
public class DefaultWagonManager extends org.apache.maven.repository.legacy.DefaultWagonManager
    implements WagonManager {

  // NOTE: This must use a different field name than in the super class or IoC has no chance to
  // inject the loggers
  @Requirement
  private Logger log;

  @Requirement
  private LegacySupport legacySupport;

  @Requirement
  private SettingsDecrypter settingsDecrypter;

  @Requirement
  private MirrorSelector mirrorSelector;

  @Requirement
  private ArtifactRepositoryFactory artifactRepositoryFactory;

  public AuthenticationInfo getAuthenticationInfo(String id) {
    MavenSession session = legacySupport.getSession();

    if (session != null && id != null) {
      MavenExecutionRequest request = session.getRequest();

      if (request != null) {
        List<Server> servers = request.getServers();

        if (servers != null) {
          for (Server server : servers) {
            if (id.equalsIgnoreCase(server.getId())) {
              SettingsDecryptionResult result = settingsDecrypter.decrypt(new DefaultSettingsDecryptionRequest(server));
              server = result.getServer();

              AuthenticationInfo authInfo = new AuthenticationInfo();
              authInfo.setUserName(server.getUsername());
              authInfo.setPassword(server.getPassword());
              authInfo.setPrivateKey(server.getPrivateKey());
              authInfo.setPassphrase(server.getPassphrase());

              return authInfo;
            }
          }
        }
      }
    }

    // empty one to prevent NPE
    return new AuthenticationInfo();
  }

  public ProxyInfo getProxy(String protocol) {
    MavenSession session = legacySupport.getSession();

    if (session != null && protocol != null) {
      MavenExecutionRequest request = session.getRequest();

      if (request != null) {
        List<Proxy> proxies = request.getProxies();

        if (proxies != null) {
          for (Proxy proxy : proxies) {
            if (proxy.isActive() && protocol.equalsIgnoreCase(proxy.getProtocol())) {
              SettingsDecryptionResult result = settingsDecrypter.decrypt(new DefaultSettingsDecryptionRequest(proxy));
              proxy = result.getProxy();

              ProxyInfo proxyInfo = new ProxyInfo();
              proxyInfo.setHost(proxy.getHost());
              proxyInfo.setType(proxy.getProtocol());
              proxyInfo.setPort(proxy.getPort());
              proxyInfo.setNonProxyHosts(proxy.getNonProxyHosts());
              proxyInfo.setUserName(proxy.getUsername());
              proxyInfo.setPassword(proxy.getPassword());

              return proxyInfo;
            }
          }
        }
      }
    }

    return null;
  }

  public void getArtifact(Artifact artifact, ArtifactRepository repository)
      throws TransferFailedException, ResourceDoesNotExistException {
    getArtifact(artifact, repository, null, false);
  }

  public void getArtifact(Artifact artifact, List<ArtifactRepository> remoteRepositories)
      throws TransferFailedException, ResourceDoesNotExistException {
    getArtifact(artifact, remoteRepositories, null, false);
  }

  @Deprecated
  public ArtifactRepository getMirrorRepository(ArtifactRepository repository) {

    Mirror mirror = mirrorSelector.getMirror(repository, legacySupport.getSession().getSettings().getMirrors());

    if (mirror != null) {
      String id = mirror.getId();
      if (id == null) {
        // TODO: this should be illegal in settings.xml
        id = repository.getId();
      }

      log.debug("Using mirror: " + mirror.getUrl() + " (id: " + id + ")");

      repository = artifactRepositoryFactory.createArtifactRepository(id, mirror.getUrl(), repository.getLayout(),
          repository.getSnapshots(), repository.getReleases());
    }
    return repository;
  }

}
